package com.baijiaoxi.common.model.asyncjob;

import lombok.extern.slf4j.Slf4j;

@Slf4j
public class DefaultAsyncJobPublishCallback implements AsyncJobPublishCallback {
    @Override
    public void onException(Throwable e) {
        log.error("mq发送失败：", e);
    }

    @Override
    public void onSuccess(Object message) {
        log.info("消息发送成功:{}", message);
    }


}
